
 /**
 * 上海中赢金融信息服务有限公司
 * Copyright (c) 2017, chinazyjr All Rights Reserved.
 */
package com.sys.kafka.core.consumer;

import java.util.List;

import com.sys.kafka.core.consumer.listener.MessageListener;

/**
 * <b>Description：</b> TODO <br/>
 * <b>ClassName：</b> IConsumerHandler <br/>
 * <b>@author：</b> mobing <br/>
 * <b>@date：</b> 2017年7月13日 下午4:34:20 <br/>
 * <b>@version: </b>  <br/>
 */
public interface IConsumerHandler {

    public void subscribe(List<String> topics) ;
    
    public void subscribe(String topic);
    
    public void register(String topic,MessageListener listener);
    
    public void start();
}
